async def aq_update_is_st(self, today):
    logger.logger.warning("start loading st data")
    path = Path(root_path) / "quote" / "st"
    store = DailyStorage(path.as_posix())
    all_codes = JQ_read.get_index_or_stock_codes(["stock"], today=today)
    data_list = []
    try:
        pd_data = get_extras("is_st", all_codes, start_date=today, end_date=today)
        for column in pd_data.columns.tolist():
            data = pd.DataFrame(pd_data[column])
            data = data.rename(columns={column: "is_st"})
            data["is_st"] = data["is_st"].astype("int")
            data["dt"] = pd_data.index
            data["dt"] = data["dt"].apply(lambda x: str(x)[0:10])
            data["symbol"] = column
            data["year"] = data["dt"].apply(lambda x: str(x)[0:4])
            data_list.append(data)
        end_data = pd.concat(data_list, ignore_index=True)
        await store.append_data(end_data)
    except Exception:
        logger.logger.warning("写入数据失败 %s" % str(today))


    async def aq_update_factor(self, today):
        logger.logger.warning("starting download factor data")
        path = Path(root_path) / "quote" / "factor"
        store = DailyStorage(path.as_posix())
        data_list = []
        all_codes = JQ_read.get_index_or_stock_codes(
            ["stock", "fund", "index"], today=today
        )
        pre_data = get_price(
            all_codes, count=1, end_date=today, fields=["factor"], fq="pre"
        )
        post_data = get_price(
            all_codes, count=1, end_date=today, fields=["factor"], fq="post"
        )
        for code in all_codes:
            end_data = pre_data.minor_xs(code)
            end_data = end_data.rename(columns={"factor": "pre_factor"})
            end_data["dt"] = end_data.index
            end_data["dt"] = end_data["dt"].apply(lambda x: str(x)[0:10])
            end_data["year"] = end_data["dt"].apply(lambda x: x[0:4])
            end_data["post_factor"] = post_data.minor_xs(code)["factor"]
            end_data["symbol"] = code
            data_list.append(end_data)
        slave_data = pd.concat(data_list, ignore_index=False)
        await store.append_data(slave_data















